package com.luban.producer.service;

import org.apache.rocketmq.spring.core.RocketMQLocalTransactionState;
import org.springframework.messaging.Message;

import java.util.Map;

/**
 * 需要视频资料或咨询课程的同学可以添加若曦老师的QQ:2746251334
 */
public interface TestService {

    /**
     * 操作事务
     */
    RocketMQLocalTransactionState insert(Message message);


    /**
     * 检查事务
     */
    int checkTransaction(String id);


    /**
     * 发送事务消息
     */

    void  sendTransactionMessage(Map<String,Object> map);


}
